package com.kai.service.mqtt.consumer;

import lombok.Data;
import org.eclipse.paho.client.mqttv3.MqttMessage;

@Data
public abstract class MessageConsumerAbstract {

    public abstract void consume(MqttMessage mqttMessage);
}
